package com.rn.gypsophila.redis.queue.pubsub;

import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;

/**
 * Description: Redis消息订阅者
 *
 * @author 然诺
 * @date 2020/05/09
 */
public class RedisMessageSubscriber implements MessageListener {

	@Override
	public void onMessage(Message message, byte[] bytes) {
		System.out.println("Message received: " + message.toString());
	}

}
